//1.引入第三方模块
const express = require('express');
//2.需要用到mysql，要引入连接池模块
const pool = require('../pool');
//3.创建路由对象
const router = express.Router();
//以下为处理逻辑
//(1)用户注册
//页面地址：http://127.0.0.1:8080/register.html
//请求方式:POST
//路由地址：/user/register
//接收参数：req.body
router.post('/register',(req,res,next)=>{
  let obj = req.body;
  // console.log(obj);
  pool.query('insert into users set ?',[obj],(err,data)=>{
    if(err){next(err);return;}
     console.log(data.affectedRows);
    if(data.affectedRows==1){
      res.send({
        "code":1,
        "msg":"注册成功"
      })
    }else {
      res.send({
        "code":0,
        "msg":"注册失败"
      })
    }
  })
})
/*会员登录*/ 
//接收传参的方法：req.body
router.post('/users', (req, res, next) => {
  //查看前台传值是否已到
  let obj = req.body;
   console.log(obj);
  //执行sql查询
  pool.query("select * from users where username=? and upassword=?", [obj.aname,obj.apwd], (err, data) => {
    //排错,处理错误
    if (err) {
      next(err);
      return;
    }
    //查看数据库是否返回查询结果
    //[ RowDataPacket { a_id: 1, a_names: 'zhangsan', a_pwd: '123' } ]
    console.log(data);
    if (data.length == 0) {
      //没查到数据
      res.send({
        "code": 0,
        "msg": "没找到数据",
        "data":data
      });
    } else {
      res.send({
        "code": 1,
        "msg": "有用户数据",
        "data":data
      })
    }
  })

})


/*
//(2)用户修改个人信息
//页面地址：http://127.0.0.1:8080/edit.html
//请求方式:PUT
//路由地址：/user/edit
//接收参数：req.body
router.put('/admin/newuser',(req,res,next)=>{
  var obj = req.body;
  pool.query(`update users set u_names="${obj.uname}",u_phone="${obj.uphone}",u_member="${obj.umember}" where u_phone="${obj.oldphone}";`,(err,data)=>{
    if(err){next(err);return;}
    if(data.affectedRows==1){
      res.send({
        "code":1,
        "msg":"修改成功"
      })
    }else {
      res.send({
        "code":0,
        "msg":"修改失败"
      })
    }
  })
})
*/

//最后一步，导出（暴露）路由对象
module.exports = router;